package com.bossien.flink.common;

import com.bossien.flink.interfaces.IExcutionPostResult;
import lombok.Data;
import lombok.experimental.Accessors;

/**
 * @author 胡春林
 * 集群中间结果发送至redis
 */
@Data
@Accessors(chain = true)
public class ExcutionEnvironmentResult<T> implements IExcutionPostResult {

    private T result;

    //发送者队列名
    private String queueNameExc;

    @Override
    public <T> T postResult(T t) {

        return null;
    }
}
